package com.ferry.transport.netty.cluster;

import com.ferry.protocol.StatusCode;
import com.ferry.protocol.payload.RequestPayload;
import com.ferry.transport.api.channel.FutureListener;
import com.ferry.transport.api.channel.WrappedChannel;
import com.ferry.transport.netty.consumer.Connector;
import com.ferry.transport.netty.consumer.Response;
import com.ferry.transport.netty.future.future.InvokeFuture;
import com.ferry.transport.netty.lb.LoadBalancer;
import com.ferry.transport.netty.provider.MessageWrapper;
import com.ferry.transport.netty.provider.Request;
import com.ferry.transport.netty.provider.RespWrapper;

import java.io.WriteAbortedException;

/**
 * Created by daiyong
 */
public class FailfastClusterInvoker extends AbstractClusterInvoker{

	public FailfastClusterInvoker(LoadBalancer loadBalancer, Connector connector) {
		super(loadBalancer, connector);
	}

	@Override
	public InvokeFuture invoke(Request request) {
		return write(request);
	}
}
